﻿#ifndef __UPLOAD_DATABASE_H_
#define __UPLOAD_DATABASE_H_
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <dirent.h>
#include <assert.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <time.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/shm.h>
#include <signal.h>
#include <pthread.h>
#include <mysql/mysql.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/epoll.h>
#include "cJSON.h"
#include "register_and_login.h"
#include"share_data.h"

#define password "1"



MYSQL* connect_mysql();
void data_insert_database(USE* data, MYSQL* connect);//管理员注册信息插入数据库
void data_insert_database2(USE* data, MYSQL* connect);//用户注册信息插入数据库

USE* read_mysql_to_list(MYSQL* connect, USE* head);//读取数据库里面的管理员信息到链表当中
USE* read_mysql_to_list2(MYSQL* connect, USE* head);////读取数据库里面的用户信息到链表当中


int pump_data_insert_database3(WP* data, MYSQL* connect);//水泵的1号功能插入使用
WP* read_mysql_to_list3(MYSQL* connect, WP* head);//水泵的3号功能查询使用
int pump_data_delete_database3(WP* data, MYSQL* connect);////水泵的2号功能删除使用


DAT* read_mysql_to_data_list(MYSQL* connect, DAT* head);//把具体数据读取到链表当中-具体数据的1号功能查询使用


int data_insert_database4(DAT* data, MYSQL* connect);//这是循环发客户端,一直上传到数据库

#endif
